package com.jeffse.light.stream.core.function.base;

import com.jeffse.light.stream.core.data.context.ProcessContext;

public interface AbstractProcessFunction <T, O> extends Function, ProcessContext<O> {
    public void processElement(ProcessContext context, T value) throws Exception;
}
